const express = require('express');
const axios = require('axios');
const bodyParser = require('body-parser');
const crypto = require('crypto');

const app = express();
const port = 3000; // 或者其他你选择的端口

// 讯飞API的Key和Secret
const API_KEY = '589c91dc6f3ff6ecdfe61325e2e04cce';
const API_SECRET = 'ZWE1YTM4YjUxZDlmMzk2MjAzYTUzZmE0';
const API_PASSWORD = 'TxzJeFLjadHOxDaslMWE:KLwNEhVncSOckvGPfSoL';
// 讯飞对话API的URL（这里只是一个示例，实际URL请查阅讯飞API文档）
const API_URL = 'https://spark-api-open.xf-yun.com/v1/chat/completions';
// 中间件设置
app.use(bodyParser.json());

const coustpmerserver = async(input) =>{
    console.log(input);
    const config = {
    headers: {
      'Content-Type': 'application/json', // 根据API要求设置内容类型
      'Authorization': `Bearer ${API_PASSWORD}`, // 根据API要求设置授权信息
    },
  };
    const response = await axios.post(API_URL, {
    "model": "generalv3.5",
    "user": "user_123456",
    "messages": [
        {
            "role": "user",
            "content": input
        }
    ],
    },config
    );
    console.log(response.data);
    return response.data;
}
module.exports = coustpmerserver;

// // 生成签名函数（根据讯飞API的要求实现）
// function generateSignature(params, secret) {
//   // ... 实现签名生成逻辑
//   return signature;
// }

// // 对话接口路由
// app.post('/chat', async (req, res) => {
//   const { text } = req.body;

//   // 准备请求参数（根据讯飞API的要求）
//   const params = {
//     appid: API_KEY,
//     // ... 其他必要的参数
//     text,
//     // 签名参数（放在最后，或者根据API文档的要求放置）
//     sign: generateSignature({ /* 参数列表，包括appid和text等 */ }, API_SECRET),
//   };
//   const config = {
//     headers: {
//       'Content-Type': 'application/json', // 根据API要求设置内容类型
//       'Authorization': `Bearer ${API_PASSWORD}`, // 根据API要求设置授权信息
//     },
//   };
//   try {
//     const response = await axios.post(API_URL, params, config);
//     // 处理讯飞API的响应，并返回给前端
//     res.json(response.data);
//   } catch (error) {
//     // 处理错误，并返回错误信息给前端
//     res.status(500).json({ error: 'Server error' });
//   }
// });

// // 启动服务器
// app.listen(port, () => {
//   console.log(`Server is running on http://localhost:${port}`);
// });

// const express = require('express');
// const axios = require('axios');
// const bodyParser = require('body-parser');

// const app = express();
// app.use(bodyParser.json());

// // const API_KEY = 'your_api_key';
// // const API_SECRET = 'your_api_secret';
// // const API_URL = 'https://api.xfyun.cn/v1/service/v1/iat'; // 替换为实际的API URL
// const API_KEY = '589c91dc6f3ff6ecdfe61325e2e04cce';
// const API_SECRET = 'ZWE1YTM4YjUxZDlmMzk2MjAzYTUzZmE0';
// const API_PASSWORD = 'TxzJeFLjadHOxDaslMWE:KLwNEhVncSOckvGPfSoL';
// // 讯飞对话API的URL（这里只是一个示例，实际URL请查阅讯飞API文档）
// const API_URL = 'https://spark-api-open.xf-yun.com/v1/chat/completions';

// app.post('/ask', async (req, res) => {
//     const question = req.body.question;
//     console.log(question);
//     // try {
//     //     const response = await axios.post(API_URL, {
//     //         // 这里需要根据讯飞API文档填写具体的请求参数
//     //         question: question,
//     //         apiKey: API_KEY,
//     //         apiSecret: API_SECRET
//     //     });
//     //     res.json({ answer: response.data.answer });
//     // } catch (error) {
//     //     console.error(error);
//     //     res.status(500).send('Error occurred while fetching the answer');
//     // }
// });

// const PORT = process.env.PORT || 3001;
// app.listen(PORT, () => {
//     console.log(`Server is running on port ${PORT}`);
// });
